Source code for pybaram.backends.types

# -*- coding: utf-8 -*-
from mpi4py import MPI
import numpy as np



class ArrayBank:
    """
    ArrayBank object

    It stores list of arrays and point one of them.
    """
    def __init__(self, mat, idx):
        # Curren index
        self.idx = idx

        # Bank of array
        self.mat = mat

    @property
    def value(self):
        # Return current array in the bank
        return self.mat[self.idx]



class NullKernel:
    def __call__(self, *args):
        pass




class Kernel:
    """
    Kernel object

    It stores the static arguments.
    It executes function with static and dynamic arguments
    """
    def __init__(self, fun, *args, arg_trans_pos=False):
        # Store functions and static argument
        self._fun = fun
        self._args = args

        # Transpose argument for execute function
        if arg_trans_pos:
            self._sum_args = lambda x, y : y + x 
        else:
            self._sum_args = lambda x, y : x + y

    def __call__(self, *args):
        # Merge static argument and dynamic argument
        args = self._sum_args(self._args, args)

        # Parse args for Array bank object
        args = [arg.value if hasattr(arg, 'value') else arg for arg in args]

        # Run function
        return self._fun(*args)

    def update_args(self, *args):
        # Update static argument
        self._args = args

    @property
    def is_compiled(self):
        # Check the function is already JIT compiled or not
        return self._fun.signatures != []





class MetaKernel:
    """
    Meta kernel object

    It stores series of kernels and run all them.
    """
    def __init__(self, kerns):
        # Store series of kernels
        self._kerns = kerns
    
    def __call__(self, *args):
        # Run all kernel squentially
        for kern in self._kerns:
            kern.__call__(*args)





class Queue:
    """
    Simple Queue

    It collects MPI requests and synchronizes all these commnunications.
    """
    def __init__(self):
        self._reqs = []



    def sync(self):
        # Fire-off the stacked requests in the queue
        MPI.Prequest.Waitall(self._reqs)
        self._reqs = []




    def register(self, *reqs):
        # Stack mpi requests
        for req in reqs:
            self._reqs.append(req)